package com.example.websocketclusterspringbootstarter.helper;

import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;

import javax.annotation.Resource;

/**
 * 数据跨jvm传输helper
 *
 * @author zhucc
 * @date 2022-03-08
 */
@Component
public class TransferHelper {

    @Resource
    private RedisTemplate<String, String> redisComponent;

    /**
     * @param nodeName to 所在节点的名称
     * @param o        需要传输的对象jsonStr
     */
    //TODO 暂为实现其他序列化方式的传输，目前仅支持json
    public void transfer(String nodeName, String o) {
        redisComponent.opsForList().leftPush(nodeName, o);
    }

}
